package com.ruoyi.gateway.service;

import com.ruoyi.gateway.service.impl.MqttServerServiceImpl;

import java.util.Map;

public interface MqttServerService {

    void sendToDevice(String clientId, String topic, byte[] payload);

    void sendToDevice(String clientId, String topic, String message);

    boolean isDeviceOnline(String clientId);

    Map<String, MqttServerServiceImpl.ClientSession> getOnlineDevices();

    void disconnectDevice(String clientId);
}
